package com.lee.channel;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @Description TODO
 * @Author winston
 * @DateTime 2022/8/25
 */
public interface InputChannel {

    String order_input = "order_queue";
    String order_input_2 = "order_queue_2";

    String oa_input = "in_oa";
    String oa_input_2 = "in_oa_2";

    @Input(value = order_input)
    SubscribableChannel orderSubScribe();

    @Input(value = order_input_2)
    SubscribableChannel orderSubScribe2();

    @Input(value = oa_input)
    SubscribableChannel oaSubScribe();

    @Input(value = oa_input_2)
    SubscribableChannel oaSubScribe2();
}
